package com.picc.app.dao.kafka;

import com.picc.app.common.kafka.entity.dto.NewEvent;
import org.apache.ibatis.annotations.Param;

/**
 * @author: 张一卓
 * @date: 2021/5/8
 **/
public interface NewPostgreDao {
    /**
     * 新增数据
     * 或更新数据
     *
     * @param event 实例对象
     * @return 影响行数
     */
    int save(NewEvent event, @Param("table") String table);

    /**
     * 通过主键删除数据
     *
     * @param event 主键
     * @return 影响行数
     */
    int deleteById(NewEvent event, @Param("table") String table);

    int select(NewEvent event, @Param("table") String table);

    //postgresql特殊upsert语法
    int upsert(NewEvent event, @Param("table") String table);
}
